Node / meshtastic / Meshtastic-Android / files / core / data / src / commonTest / kotlin / org / meshtastic / core / data / manager / GeofenceMonitorTest.kt

Displaying Raw • Download

T8b949e/*

* Copyright (c) 2026 Meshtastic LLC

*

* This program is free software: you can redistribute it and/or modify

* it under the terms of the GNU General Public License as published by

* the Free Software Foundation, either version 3 of the License, or

* (at your option) any later version.

*

* This program is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the

* GNU General Public License for more details.

*

* You should have received a copy of the GNU General Public License

* along with this program. If not, see <https://www.gnu.org/licenses/>.

*/

Tff7b72package T7ee787org.meshtastic.core.data.manager

Tff7b72import T7ee787dev.mokkery.MockMode

Tff7b72import T7ee787dev.mokkery.answering.returns

Tff7b72import T7ee787dev.mokkery.every

Tff7b72import T7ee787dev.mokkery.matcher.any

Tff7b72import T7ee787dev.mokkery.mock

Tff7b72import T7ee787dev.mokkery.verify.VerifyMode.Companion.exactly

Tff7b72import T7ee787dev.mokkery.verifySuspend

Tff7b72import T7ee787kotlinx.coroutines.ExperimentalCoroutinesApi

Tff7b72import T7ee787kotlinx.coroutines.cancel

Tff7b72import T7ee787kotlinx.coroutines.flow.MutableStateFlow

Tff7b72import T7ee787kotlinx.coroutines.flow.flowOf

Tff7b72import T7ee787kotlinx.coroutines.test.StandardTestDispatcher

Tff7b72import T7ee787kotlinx.coroutines.test.TestScope

Tff7b72import T7ee787kotlinx.coroutines.test.advanceUntilIdle

Tff7b72import T7ee787kotlinx.coroutines.test.runTest

Tff7b72import T7ee787org.meshtastic.core.model.DataPacket

Tff7b72import T7ee787org.meshtastic.core.model.Node

Tff7b72import T7ee787org.meshtastic.core.repository.MeshNotificationManager

Tff7b72import T7ee787org.meshtastic.core.repository.NodeManager

Tff7b72import T7ee787org.meshtastic.core.repository.NotificationPrefs

Tff7b72import T7ee787org.meshtastic.core.repository.PacketRepository

Tff7b72import T7ee787org.meshtastic.core.repository.RadioInterfaceService

Tff7b72import T7ee787org.meshtastic.proto.Position

Tff7b72import T7ee787org.meshtastic.proto.Waypoint

Tff7b72import T7ee787kotlin.test.Test

T8b949e/**

* Covers the crossing-decision logic deterministically via virtual time. The positive notification *dispatch* (R9) is

* NOT asserted here: it is gated behind `getStringSuspend` (compose-resources), which does not resolve in the plain-JVM

* test runner, so any test reaching it hangs. Coverage is instead structured around negatives that still drive the full

* decision path right up to the notify entry point:

* - [favoritesOnlySuppressesNonFavoriteCrossing] drives a real outside→inside ENTER and is stopped only by the gate,

* proving the snapshot/worker/store/enter-branch all work.

* - [enterOnlyWaypointDoesNotNotifyOnExit] proves the EXIT branch is gated by `notify_on_exit`. The actual dispatch

* (contactKey/channel/deep-link) is verified by code review + manual run.

*/

Tf0883e@OptInTb4b4b4(Te6edf3ExperimentalCoroutinesApiTff7b72::Te6edf3classTb4b4b4)

Tff7b72class T56d364GeofenceMonitorTest Tb4b4b4{

Tff7b72private Tff7b72val Te6edf3sender Tff7b72= T79c0ff9

Tff7b72private Tff7b72val Te6edf3myNodeNum Tff7b72= T79c0ff1

T8b949e// Geofence centred at (10, 20), 1 km radius.

Tff7b72private Tff7b72val Te6edf3centerLatI Tff7b72= T79c0ff1T79c0ff0T79c0ff0Te6edf3_000_000

Tff7b72private Tff7b72val Te6edf3centerLonI Tff7b72= T79c0ff2T79c0ff0T79c0ff0Te6edf3_000_000

Tff7b72private Tff7b72val Te6edf3inside Tff7b72= Te6edf3PositionTb4b4b4(Te6edf3latitude_i Tff7b72= Te6edf3centerLatITb4b4b4, Te6edf3longitude_i Tff7b72= Te6edf3centerLonITb4b4b4) T8b949e// distance 0

Tff7b72private Tff7b72val Te6edf3outside Tff7b72= Te6edf3PositionTb4b4b4(Te6edf3latitude_i Tff7b72= T79c0ff1T79c0ff1T79c0ff0Te6edf3_000_000Tb4b4b4, Te6edf3longitude_i Tff7b72= Te6edf3centerLonITb4b4b4) T8b949e// ~111 km north

Tff7b72private Tff7b72fun Td2a8ffwaypointTb4b4b4(Te6edf3enterTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72trueTb4b4b4, Te6edf3exitTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4, Te6edf3favoritesOnlyTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4) Tff7b72= Te6edf3WaypointTb4b4b4(

Te6edf3id Tff7b72= T79c0ff4T79c0ff2Tb4b4b4,

Te6edf3latitude_i Tff7b72= Te6edf3centerLatITb4b4b4,

Te6edf3longitude_i Tff7b72= Te6edf3centerLonITb4b4b4,

Te6edf3name Tff7b72= Ta5d6ff"Ta5d6ffBaseTa5d6ff"Tb4b4b4,

Te6edf3geofence_radius Tff7b72= T79c0ff1T79c0ff0T79c0ff0T79c0ff0Tb4b4b4,

Te6edf3notify_on_enter Tff7b72= Te6edf3enterTb4b4b4,

Te6edf3notify_on_exit Tff7b72= Te6edf3exitTb4b4b4,

Te6edf3notify_favorites_only Tff7b72= Te6edf3favoritesOnlyTb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72data Tff7b72class T56d364MocksTb4b4b4(

Tff7b72val Te6edf3packetRepositoryTb4b4b4: Te6edf3PacketRepositoryTb4b4b4,

Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManagerTb4b4b4,

Tff7b72val Te6edf3notificationsTb4b4b4: Te6edf3MeshNotificationManagerTb4b4b4,

Tff7b72val Te6edf3notificationPrefsTb4b4b4: Te6edf3NotificationPrefsTb4b4b4,

Tb4b4b4)

Tff7b72private Tff7b72fun Td2a8ffmocksTb4b4b4(

Te6edf3wpTb4b4b4: Te6edf3WaypointTb4b4b4,

Te6edf3senderIsFavoriteTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3createdByLocalTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3optedInIdsTb4b4b4: Te6edf3SetTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3emptySetTb4b4b4(Tb4b4b4)Tb4b4b4,

Tb4b4b4)Tb4b4b4: Te6edf3Mocks Tb4b4b4{

Tff7b72val Te6edf3packetRepositoryTb4b4b4: Te6edf3PacketRepository Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)

Tff7b72val Te6edf3nodeManagerTb4b4b4: Te6edf3NodeManager Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)

Tff7b72val Te6edf3notificationsTb4b4b4: Te6edf3MeshNotificationManager Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)

Tff7b72val Te6edf3notificationPrefsTb4b4b4: Te6edf3NotificationPrefs Tff7b72= Te6edf3mockTb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)

T8b949e// from defaults to ^local (locally created); a remote creator uses another node's hex id.

Tff7b72val Te6edf3packet Tff7b72=

Te6edf3DataPacketTb4b4b4(Te6edf3to Tff7b72= Ta5d6ff"Ta5d6ff!abcdabcdTa5d6ff"Tb4b4b4, Te6edf3channel Tff7b72= T79c0ff0Tb4b4b4, Te6edf3waypoint Tff7b72= Te6edf3wpTb4b4b4)Tb4b4b4.Te6edf3also Tb4b4b4{

Tff7b72if Tb4b4b4(Tff7b72!Te6edf3createdByLocalTb4b4b4) Tffa657itTb4b4b4.Te6edf3from Tff7b72= Ta5d6ff"Ta5d6ff!0000000Tffd700$Te6edf3senderTa5d6ff"

Tb4b4b4}

Te6edf3every Tb4b4b4{ Te6edf3packetRepositoryTb4b4b4.Te6edf3getWaypointsTb4b4b4(Tb4b4b4) Tb4b4b4} Te6edf3returns Te6edf3flowOfTb4b4b4(Te6edf3listOfTb4b4b4(Te6edf3packetTb4b4b4)Tb4b4b4)

Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3myNodeNum Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Te6edf3myNodeNumTb4b4b4)

Te6edf3every Tb4b4b4{ Te6edf3nodeManagerTb4b4b4.Te6edf3nodeDBbyNodeNum Tb4b4b4} Te6edf3returns Te6edf3mapOfTb4b4b4(Te6edf3sender Te6edf3to Te6edf3NodeTb4b4b4(Te6edf3num Tff7b72= Te6edf3senderTb4b4b4, Te6edf3isFavorite Tff7b72= Te6edf3senderIsFavoriteTb4b4b4)Tb4b4b4)

Te6edf3every Tb4b4b4{ Te6edf3notificationPrefsTb4b4b4.Te6edf3geofenceAlertOptIns Tb4b4b4} Te6edf3returns Te6edf3MutableStateFlowTb4b4b4(Te6edf3optedInIdsTb4b4b4)

Tff7b72return Te6edf3MocksTb4b4b4(Te6edf3packetRepositoryTb4b4b4, Te6edf3nodeManagerTb4b4b4, Te6edf3notificationsTb4b4b4, Te6edf3notificationPrefsTb4b4b4)

Tb4b4b4}

Tff7b72private Tff7b72fun Td2a8ffexpectNoNotificationTb4b4b4(

Te6edf3wpTb4b4b4: Te6edf3WaypointTb4b4b4,

Te6edf3senderIsFavoriteTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72falseTb4b4b4,

Te6edf3createdByLocalTb4b4b4: Tffa657Boolean Tff7b72= Tff7b72trueTb4b4b4,

Te6edf3optedInIdsTb4b4b4: Te6edf3SetTff7b72<Tffa657IntTff7b72> Tff7b72= Te6edf3emptySetTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3driveTb4b4b4: Tb4b4b4(Te6edf3GeofenceMonitorTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,

Tb4b4b4) Tff7b72= Te6edf3runTest Tb4b4b4{

Tff7b72val Te6edf3scope Tff7b72= Te6edf3TestScopeTb4b4b4(Te6edf3StandardTestDispatcherTb4b4b4(Te6edf3testSchedulerTb4b4b4)Tb4b4b4)

Tff7b72val Te6edf3m Tff7b72= Te6edf3mocksTb4b4b4(Te6edf3wpTb4b4b4, Te6edf3senderIsFavoriteTb4b4b4, Te6edf3createdByLocalTb4b4b4, Te6edf3optedInIdsTb4b4b4)

Tff7b72val Te6edf3monitor Tff7b72=

Te6edf3GeofenceMonitorTb4b4b4(

Te6edf3lazy Tb4b4b4{ Te6edf3mTb4b4b4.Te6edf3packetRepository Tb4b4b4}Tb4b4b4,

Te6edf3mTb4b4b4.Te6edf3nodeManagerTb4b4b4,

Te6edf3mTb4b4b4.Te6edf3notificationsTb4b4b4,

Te6edf3GeofenceCrossingStoreTb4b4b4(Tb4b4b4)Tb4b4b4,

Te6edf3mTb4b4b4.Te6edf3notificationPrefsTb4b4b4,

Te6edf3mockTff7b72<Te6edf3RadioInterfaceServiceTff7b72>Tb4b4b4(Te6edf3MockModeTb4b4b4.Te6edf3autofillTb4b4b4)Tb4b4b4,

Te6edf3scopeTb4b4b4,

Tb4b4b4)

Te6edf3scopeTb4b4b4.Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4) T8b949e// collect the active-geofence snapshot

Te6edf3driveTb4b4b4(Te6edf3monitorTb4b4b4)

Te6edf3scopeTb4b4b4.Te6edf3advanceUntilIdleTb4b4b4(Tb4b4b4)

Te6edf3verifySuspendTb4b4b4(Te6edf3exactlyTb4b4b4(T79c0ff0Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3mTb4b4b4.Te6edf3notificationsTb4b4b4.Te6edf3updateWaypointNotificationTb4b4b4(Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3anyTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4}

Te6edf3scopeTb4b4b4.Te6edf3cancelTb4b4b4(Tb4b4b4) T8b949e// stop the serial worker so runTest sees no leaked coroutine

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8fffirstSightingInsideDoesNotNotifyTb4b4b4(Tb4b4b4) Tff7b72=

Te6edf3expectNoNotificationTb4b4b4(Te6edf3waypointTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3m Tff7b72-Tff7b72> Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3insideTb4b4b4) Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8fffavoritesOnlySuppressesNonFavoriteCrossingTb4b4b4(Tb4b4b4) Tff7b72=

Te6edf3expectNoNotificationTb4b4b4(Te6edf3waypointTb4b4b4(Te6edf3favoritesOnly Tff7b72= Tff7b72trueTb4b4b4)Tb4b4b4, Te6edf3senderIsFavorite Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4{ Te6edf3m Tff7b72-Tff7b72>

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3outsideTb4b4b4) T8b949e// baseline

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3insideTb4b4b4) T8b949e// genuine ENTER, but sender is not a favorite

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffownPositionIsNeverEvaluatedTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3expectNoNotificationTb4b4b4(Te6edf3waypointTb4b4b4(Tb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3m Tff7b72-Tff7b72>

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3myNodeNumTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3insideTb4b4b4) T8b949e// sender == self

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffremoteCreatedGeofenceDoesNotNotifyTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3expectNoNotificationTb4b4b4(Te6edf3waypointTb4b4b4(Tb4b4b4)Tb4b4b4, Te6edf3createdByLocal Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4{ Te6edf3m Tff7b72-Tff7b72>

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3outsideTb4b4b4) T8b949e// baseline

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3insideTb4b4b4) T8b949e// genuine ENTER, but we didn't create this geofence

Tb4b4b4}

Tf0883e@Test

Tff7b72fun Td2a8ffenterOnlyWaypointDoesNotNotifyOnExitTb4b4b4(Tb4b4b4) Tff7b72= Te6edf3expectNoNotificationTb4b4b4(Te6edf3waypointTb4b4b4(Te6edf3enter Tff7b72= Tff7b72trueTb4b4b4, Te6edf3exit Tff7b72= Tff7b72falseTb4b4b4)Tb4b4b4) Tb4b4b4{ Te6edf3m Tff7b72-Tff7b72>

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3insideTb4b4b4) T8b949e// baseline inside

Te6edf3mTb4b4b4.Te6edf3onPositionReceivedTb4b4b4(Te6edf3senderTb4b4b4, Te6edf3myNodeNumTb4b4b4, Te6edf3outsideTb4b4b4) T8b949e// EXIT, but notify_on_exit is false

Tb4b4b4}

Tb4b4b4}